package com.yaxin.outsourcing.utils;

import com.yaxin.common.core.utils.StringUtils;
import com.yaxin.outsourcing.domain.LoginResult;
import org.springframework.boot.configurationprocessor.json.JSONObject;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.URL;
import java.net.URLConnection;
import java.util.Date;

public class OaLoginUtil {
    static final String  URL_SSOLOGIN="/x_organization_assemble_authentication/jaxrs/sso";

    //服务地址：http://127.0.0.1:20020/x_organization_assemble_authentication/jaxrs/sso
    //{"token":"xadmin","client":"sso_demo"}
    /**
     * 使用登录认证的接口进行服务器登录，获取xtoken信息
     * @param applicationServer  127.0.0.1
     * @param applicationPort     20020
     * @param userName             张三
     * @param client                    sso_demo
     * @param key                       sso123456
     * @return
     * @throws Exception
     */
    public static LoginResult login(String applicationServer, Integer applicationPort, String userName, String client, String key ) throws Exception {
        //参数
        String loginUrl = "http://" + applicationServer + ":" + applicationPort + URL_SSOLOGIN ;
        String xtoken = Crypto.encrypt( userName + "#" + new Date().getTime(), key );
        String loginParams = String.format("{'token':'%s','client':'%s'}", xtoken, client );
        String responseData = sendPost( loginUrl, loginParams );

        JSONObject result = new JSONObject(responseData);
        String type = result.getString("type");
        if( StringUtils.equals( "success", type )) {
            //登录成功
            JSONObject data = result.getJSONObject("data");
            String token = data.getString( "token" );
            return new LoginResult("success", token, "登录成功！");
        }else {
            //登录失败
            return new LoginResult("error", null, "用户登录失败！");
        }
    }

    /**
     * 发送POST请求
     * @param url  地址
     * @param param   传入的数据
     * @return
     */
    public static String sendPost( String url, String param ) {
        PrintWriter out = null;
        BufferedReader in = null;
        String result = "";
        try {
            URL realUrl = new URL(url);
            URLConnection conn = realUrl.openConnection();
            conn.setRequestProperty("accept", "*/*");
            conn.setRequestProperty("connection", "Keep-Alive");
            conn.setRequestProperty("Content-Type", "application/json; charset=utf-8");
            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            conn.setDoOutput(true);
            conn.setDoInput(true);
            out = new PrintWriter(conn.getOutputStream());
            out.print(param);
            out.flush();
            in = new BufferedReader( new InputStreamReader(conn.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        return result;
    }
}
